package com.smart.car.record.config;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.SubscribableChannel;

/**
 * @Description: TODO
 * @author: zoutao
 * @date: 2021-05-06-18:59
 */
public interface CustomerChannel {

    String OUTPUT = "output";   //这里的名称对应了spring.cloud.stream.rocketmq.bindings.<channelName>
    String INPUT = "input";

    @Output(CustomerChannel.OUTPUT)
    MessageChannel output();

    @Input(CustomerChannel.INPUT)
    SubscribableChannel input();

}